package driver

import "collecter/app/common/helper"

/**
*  MessageStruct
*  @Description: 解析后的任务消息体
 */
type MessageStruct struct {
	Key          string // 队列 key
	TaskName     string // 任务名称
	Params       string // 任务参数
	RetryTimes   int64  // 重试次数
	RetryedTimes int64  // 已经重试的次数
	PullKeys     string // 拉取队列消息时传递的队列名称，多个用逗号（英文）隔开
	PullTimeOut  int64  // 从队列拉取消息的超时时间，单位 s
	Delays       int64  // 延时队列的延时时间，单位 s
	State        string // 队列确认时传递的队列任务执行结果。success、failed
}

func GetKey(queueName string) string {
	return helper.Configer.GetString("redisQueue.queueNamePrefix") + ":" + queueName
}
